package com.storm.helloword.bolt;

import backtype.storm.topology.BasicOutputCollector;
import backtype.storm.topology.OutputFieldsDeclarer;
import backtype.storm.topology.base.BaseBasicBolt;
import backtype.storm.tuple.Tuple;

public class PrintBolt extends BaseBasicBolt {

    public void execute(Tuple tuple, BasicOutputCollector collector) {  
        String rec = tuple.getString(0);  
        System.err.println("String recieved: " + rec);  
    }  
  
    public void declareOutputFields(OutputFieldsDeclarer declarer) {  
        // do nothing  
    }

}
